package com.note.kafka.service;

import com.alibaba.fastjson.JSONObject;

/**
 * <p>【描述】：kafka 消费者</p>
 * <p>【作者】: BeyMax</p>
 * <p>【日期】: 2019-08-29</p>
 **/
public interface KafkaConsumerService {

    /**
     * <p>【描述】：采集任务配置</p>
     * <p>【方法】：sendTaskConfigKafka</p>
     * <p>【参数】: [message]</p>
     * <p>【作者】: BeyMax</p>
     * <p>【日期】: 2019-08-29</p>
     **/
    JSONObject getTaskConfigKafka(JSONObject message);
    /**
     * <p>【描述】：消费LinkedIn任务数据</p>
     * <p>【方法】：listenLinkedInTask</p>
     * <p>【参数】: [parseObject]</p>
     * <p>【作者】: BayMax</p>
     * <p>【日期】: 2020/4/30</p>
     **/
    void listenLinkedInTask(JSONObject parseObject);
}
